import redis
import json
import datetime
client = redis.Redis()
while True:  # 进入无限循环,不停发布信息
    message = input('请输入需要发布的信息：')  # 获取用户在命令行输入 的内 容。
    now_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')  # 获取当前的时间
    data = {'message': message, 'time': now_time}  # 组装为一个字典
    client.publish('pubinfo', json.dumps(data))  # 把信息以 JSON 字符串的形式发布到名为 pubinfo 的频道中。
